package com.yuzhi.master.sewage.device.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.yuzhi.master.drainRRmst.domain.vo.DrainRRmstVo;
import com.yuzhi.master.sewage.device.domain.DrainDeviceZt;


import java.util.Collection;
import java.util.List;
import java.util.Map;


/**
 * 设备实时状态数据采集表 drain_device_zt
 */
public interface IDrainDeviceZtService extends IService<DrainDeviceZt>{


    /**
     * mqtt同步物联网设置实时状态数据
     * @param mgttStr
     */
    void saveDeviceZtByMqtt(String mgttStr, DrainRRmstVo drainRRmstVo);

    /**
     * 按照设备状态统计
     * @return
     */
    Map<String, Long> countDevicesByStatus();


}
